//package com.shou.trigger.job;
//
//import com.dtflys.forest.annotation.Body;
//import com.dtflys.forest.annotation.Post;
//import com.xxl.job.core.biz.model.ReturnT;
//
//import java.util.Map;
//
///**
// * ClassName:IRuleFeignClient
// * Project:yvt-scheduler
// * Package: com.sunlight.infrastructure.gateway
// * Description
// *
// * @Author Sunlight-KHE
// * @Create 2024/12/9 9:34
// * @Version 1.0
// */
//
//public class XxlJobClient {
//
////    @Post("http://localhost:9000/xxl-job-admin/jobinfo/my_add")
////    ReturnT<String> myAdd(@Body XxlJobInfo xxlJobInfo);
////
////    @Post("http://localhost:9000/xxl-job-admin/jobinfo/my_remove")
////    ReturnT<String> myRemove(int id);
//
//    public void addJob(Map<String, Object> dataMap) {
//        String content = null;
////这里的url接口路径一定要是自己F12抓取到的
//        HttpRequest request = HttpRequest.post(addresses+"/jobinfo/add")
//                .header("Content-Type", "multipart/form-data")
////每次请求都需要带上Cookie,getCookie方法在后面
//                .header("Cookie", getCookie())
//                .form(formData);
//        try {
//            // 执行 HTTP POST 请求创建定时任务
//            HttpResponse response = request.execute();
//            String result = response.body();
//            if (StrUtil.isNotBlank(result) && 200 == response.getStatus()) {
//                //定时任务创建成功后拿到任务id
//                JSONObject jsonResponse = JSON.parseObject(result);
//                content = jsonResponse.getString("content");
//                log.info("定时任务创建成功，任务ID为：" + content);
//                //创建后的定时任务默认是STOP状态,所以我们还要通过定时任务id调度任务启动接口
//                HttpRequest requests = HttpRequest.post(adminAddresses+"/jobinfo/start")
//                        .header("Content-Type", "multipart/form-data")
//                        .header("Cookie", getCookie())
//                        .form("id",content);
//                //通过HTTP请求启动定时任务
//                HttpResponse responses = requests.execute();
//                String results = responses.body();
//                if (StrUtil.isNotBlank(results) && 200 == response.getStatus()) {
//                    log.info("定时任务{}启动成功。",content);
//                }else {
//                    log.error("定时任务{}启动失败。",content);
//                }
//            } else {
//                log.error("定时任务创建失败");
//            }
//        } catch (Exception e) {
//            log.info("定时任务创建失败，发生异常：" + e.getMessage());
//        }
//    }
//
//}
